package fun.xinnix.entity.dto;

import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;

@Data
public class KafkaMessageDto {
    @NotBlank(message = "主题名称不能为空")
    private String topicName;

    private String key;

    @NotNull(message = "消息体不能为空")
    private Object object;
}
